package com.lkx.kafka.monitor.dto;

import lombok.Data;

@Data
public class ThroughputMetrics {
    private String topicName;     // 主题名称
    private Long timestamp;       // 时间戳
    private Long produceRate;     // 生产速率(消息/秒)
    private Long consumeRate;     // 消费速率(消息/秒)
    private Long currentOffset;   // 当前位移
    private Long endOffset;       // 末端位移
    private String timeDimension; // 时间维度
    private Long previousEndOffset;   // 上次末端位移（用于计算生产速率）
    private Long previousCurrentOffset; // 上次当前位移（用于计算消费速率）
}
